package com.bean;

/**
 * @Description: TODO QQ1667847363
 * @author: xiao kun tai
 * @date:2022/1/3 11:35
 */

import lombok.Data;

@Data
public class TableProcess {
    //动态分流 Sink 常量
    public static final String SINK_TYPE_HBASE = "hbase";
    public static final String SINK_TYPE_KAFKA = "kafka";
    public static final String SINK_TYPE_CK = "clickhouse";
    //来源表
    String sourceTable;

    //操作类型 insert,update,delete
    String operateType;

    //输出类型 hbase kafka
    String sinkType;

    //输出表(主题)
    String sinkTable;

    //输出字段
    String sinkColumns;

    //主键字段
    String sinkPk;

    //建表扩展
    String sinkExtend;
}
